package com.holly.unit.kafka.model;

import lombok.AllArgsConstructor;
import lombok.Getter;

/**
 * kafka producer类型 共享,独立
 * @author yangpengpeng
 * 说明
 * 1:开启事务，如果事务ID已存在，就使用此事务ID已创建的producer.如果事务ID不存在，则创建新的producer
 * 2:非开启事务，那一定是共享，共享TCP和缓存池
 */
@Getter
@AllArgsConstructor
public enum KproducerType {
	/**
	 * 不开启事务，用这个
	 */
	PRODUCER_TYPE_NORMAL("共享"),
	/**
	 * 开启事务，用这个☺
	 */
	PRODUCER_TYPE_TRANCTION("独立");
	private final  String type;
}
